package com.example.spark.udf

import org.apache.hadoop.hive.ql.exec.UDF

class HelloUDF extends UDF {
  // 测试，为输入拼接前缀
  def evaluate(input: String): String = {
    return "UDF Scala: " + input
  }
}
